from multiprocessing import Queue,Process
import time
a=100
def write_msq(q):
    global a
    if not q.full():
        for i in range(6):
            a-=10
            q.put(a)#入队
            print('a入队的值：',a)
#出队
def read_msq(q):
    time.sleep(1)
    while not q.empty():
        print('出队时a的值：',q.get())
if __name__=='__main__':
    print('父进程开始执行代码')
    q=Queue()#由父进程创建队列，没有指定参数，说明可以接受的信息没有上限
    p1=Process(target=write_msq,args=(q,))
    p2=Process(target=read_msq,args=(q,))
    p1.start()
    p2.start()
    #等待写的进程执行结束，再去执行主进程
    p1.join()
    p2.join()
    print('------父进程执行完毕------')



